package cc.chenwh.sequence.client.sequenceclient;

import java.util.concurrent.*;

public class M3 {
    public static void main(String[] args) {
//        CyclicBarrier c = new CyclicBarrier(1, ()->{
//            try {
//                TimeUnit.SECONDS.sleep(4);
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }
//            System.out.println("CyclicBarrier执行完成。");
//        });
//
//        Runnable r = ()->{
//            try {
//                c.await();
//                System.out.println("开搞！");
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            } catch (BrokenBarrierException e) {
//                e.printStackTrace();
//            }
//        };
//
//        ExecutorService pool = Executors.newFixedThreadPool(3);
//        for (int i = 0; i <3 ; i++) {
//            pool.submit(c);
//        }
//
//
//

    }
}
